feat(ai): add abort signals and timeouts to media generation activities - #1047

#!/bin/bash
# Description: Check that media adapter option interfaces declare abortSignal.
set -euo pipefail

fd -e ts . packages/ai/src/activities --exec rg -n -C4 'abortSignal' {} \
  | rg -n 'GenerationOptions|Options|abortSignal'

echo '--- option interface declarations ---'
for name in AudioGenerationOptions TTSOptions TTSGenerationOptions TranscriptionOptions VideoJobCreateOptions ImageGenerationOptions SummarizeOptions; do
  echo "== $name =="
  ast-grep run --pattern "interface $name { \$\$\$ }" --lang typescript packages/ai/src || true
done

#!/bin/bash
set -euo pipefail

echo '--- candidate interface names and declarations ---'
rg -n "interface .*Options|abortSignal\\??:\\s*AbortSignal" packages/ai/src/activities -g '*.ts' | rg "interface|abortSignal" | head -200

echo '--- files mentioning generateAudio / generateSpeech / generateSpeechToText / createVideoJob / generateImage ---'
rg -n "generateAudio|generateSpeech|generateSpeechToText|createVideoJob|generateImage" packages/ai/src/activities -g '*.ts' | head -200

echo '--- audio activity relevant section ---'
cat -n packages/ai/src/activities/generateAudio/index.ts | sed -n '1,130p;220,260p'

echo '--- related activity option exports/imports ---'
for f in packages/ai/src/activities/generateAudio/index.ts packages/ai/src/activities/generateSpeech/index.ts packages/ai/src/activities/generateSpeechToText/index.ts packages/ai/src/activities/createVideoJob/index.ts packages/ai/src/activities/generateImage/index.ts; do
  if [ -f "$f" ]; then
    echo "==$f=="
    cat -n "$f" | sed -n '1,80p;220,260p'
  fi
done

#!/bin/bash
set -euo pipefail

echo '--- package files and scripts ---'
git ls-files 'package.json' 'packages/*/package.json' | sed -n '1,80p'
for f in package.json packages/ai/package.json; do
  if [ -f "$f" ]; then
    echo "== $f =="
    sed -n '1,180p' "$f"
  fi
done

echo '--- local TypeScript/tsc availability ---'
if command -v tsc >/dev/null 2>&1; then tsc --version; else echo 'tsc not on path'; fi
if [ -d packages/ai/node_modules/typescript ]; then tsc --version; else echo 'no packages/ai/node_modules/typescript'; fi

echo '--- exact generated option interfaces ---'
for file in \
  packages/ai/src/activities/generateAudio/index.ts \
  packages/ai/src/activities/generateSpeech/index.ts \
  packages/ai/src/activities/generateTranscription/index.ts \
  packages/ai/src/activities/generateVideo/index.ts \
  packages/ai/src/activities/generateImage/index.ts \
  packages/ai/src/activities/summarize/index.ts; do
  if [ -f "$file" ]; then
    echo "== $file =="
    sed -n '50,120p;120,145p;150,180p' "$file"
  fi
done

echo '--- adapter method signatures ---'
for file in \
  packages/ai/src/activities/generateAudio/adapter.ts \
  packages/ai/src/activities/generateSpeech/adapter.ts \
  packages/ai/src/activities/generateTranscription/adapter.ts \
  packages/ai/src/activities/generateVideo/adapter.ts \
  packages/ai/src/activities/generateImage/adapter.ts; do
  if [ -f "$file" ]; then
    echo "== $file =="
    sed -n '65,95p;170,195p' "$file"
  fi
done

echo '--- TypeScript behavior probe for omitting unused value ---'
node - 2>&1 <<'JS'
const code = `
interface ProvidedOptions {
  prompt: string;
  duration?: number;
  modelOptions?: object;
  model: string;
  logger: unknown;
}
async function generateAudio(options: ProvidedOptions) { return 1; }
const rest = { prompt: 'x', duration: 1, model: 'm', logger: {}, abortSignal: new AbortController().signal };
await generateAudio({
  ...rest,
  ...(rest.abortSignal ? { abortSignal: rest.abortSignal } : {})
});
`
console.log(code)
JS

echo '--- search adapter option declarations with abortSignal ---'
rg -n "abortSignal\\??:\\s*AbortSignal" packages/ai/src/activities/generate{Audio,Speech,Transcription,Video,Image}/adapter.ts || true

#!/bin/bash
# Description: Check whether runStreamingSummarize consumes timeout/abortSignal.
set -euo pipefail

f=packages/ai/src/activities/summarize/index.ts
ast-grep outline "$f" --items all

echo '--- runStreamingSummarize body ---'
ast-grep run --pattern 'async function* runStreamingSummarize($$$) { $$$ }' --lang typescript "$f" || \
ast-grep run --pattern 'function runStreamingSummarize($$$) { $$$ }' --lang typescript "$f"

echo '--- abort references in file ---'
rg -n 'abortSignal|abortControls|timeout|raceWithAbort' "$f"

#!/bin/bash
set -euo pipefail

f=packages/ai/src/activities/summarize/index.ts
echo '--- file line count ---'
wc -l "$f"

echo '--- summarize/export section ---'
sed -n '200,280p' "$f"

echo '--- runSummarize section ---'
sed -n '234,345p' "$f"

echo '--- all exported/defined sums ---'
rg -n 'export function summarize|function runStreamingSummarize|createSummarizeOptions|SummarizeActivityOptions|stream \?|stream:' "$f"

echo '--- broader summing/search ---'
rg -n -C 3 'runStreamingSummarize|runSummarize|timeout|abortSignal' "$f"

#!/bin/bash
set -euo pipefail

f=packages/ai/src/activities/summarize/index.ts

echo '--- runStreamingSummarize body ---'
sed -n '368,460p' "$f" | cat -n

echo '--- imports and helper definitions ---'
sed -n '1,45p' "$f" | cat -n
rg -n 'createActivityAbortControls|raceWithAbort|isActivityAbortError|abortReasonMessage|runGenerationAbort|runGenerationError|runGenerationStart|runGenerationFinish|runGenerationUsage' packages/ai/src -g '*.ts'